spring webflux Spring Webflux + Reactive Kafka (2) - Consumer 이번 역시 Reactive Kafka 를 통하여 컨슈머를 구성할 예정이고 앞서 구성한 프로듀서와 연동하여 실제 메시지를 받는것까지 구현해보려 한다. 각 토픽의 파티션은 1개씩 구성하였으며 그렇기 때문에 하나의 토픽에는 하나의 컨슈머만 붙일 수 있는 상태이다. 정상적으로 카프카 토픽이 존재함을 확인할 수 있다. 프로듀서 - 컨슈머 - 저장매체 or 프로듀서 (이 모든과정이 논블로킹으로 구성되어... kafkaSpringspring webfluxreactivewebfluxSpring bootReactive KafkaJavaJava Spring Webflux + Reactive Kafka (1) - Producer 개인적인 토이 프로젝트로 Spring Webflux & Reactive Kafka를 활용하여 API를 통한 프로듀서와 컨슈머를 구성해보려 한다. 단순히 RestController를 통해 들어온 메시지를 카프카로 전송하고 컨슈머는 카프카에서 메시지를 가져오기만 하는 굉장히 단순한 흐름이다. 주키퍼와 브로커는 각 1대씩으로 우선 구성하였고 2대 이상 클러스터는 차후 시간날때 구성하려 한다. Co... SpringreactivekafkaReactive KafkaJavaspring webfluxwebfluxSpring bootJava [Spring WebFlux] Reactive Streams란 라이브러리 및 프레임워크에 상관없이 데이터 스트림을 비동기로 다룰 수 있는 공통 메커니즘이며, 이 메커니즘을 편리하게 사용할 수 있는 인터페이스 제공 Publisher : 데이터를 만들어 통지하는 생산자 Subscriber : 데이터를 받아 처리하는 소비자 Publisher와 Subscriber는 아래 4개의 프로토콜로 데이터를 통지함 onSubscribe : 데이터 통지가 준비됐음을 통지 ... Reactive Streamsspring webfluxReactive Streams
Spring Webflux + Reactive Kafka (2) - Consumer 이번 역시 Reactive Kafka 를 통하여 컨슈머를 구성할 예정이고 앞서 구성한 프로듀서와 연동하여 실제 메시지를 받는것까지 구현해보려 한다. 각 토픽의 파티션은 1개씩 구성하였으며 그렇기 때문에 하나의 토픽에는 하나의 컨슈머만 붙일 수 있는 상태이다. 정상적으로 카프카 토픽이 존재함을 확인할 수 있다. 프로듀서 - 컨슈머 - 저장매체 or 프로듀서 (이 모든과정이 논블로킹으로 구성되어... kafkaSpringspring webfluxreactivewebfluxSpring bootReactive KafkaJavaJava Spring Webflux + Reactive Kafka (1) - Producer 개인적인 토이 프로젝트로 Spring Webflux & Reactive Kafka를 활용하여 API를 통한 프로듀서와 컨슈머를 구성해보려 한다. 단순히 RestController를 통해 들어온 메시지를 카프카로 전송하고 컨슈머는 카프카에서 메시지를 가져오기만 하는 굉장히 단순한 흐름이다. 주키퍼와 브로커는 각 1대씩으로 우선 구성하였고 2대 이상 클러스터는 차후 시간날때 구성하려 한다. Co... SpringreactivekafkaReactive KafkaJavaspring webfluxwebfluxSpring bootJava [Spring WebFlux] Reactive Streams란 라이브러리 및 프레임워크에 상관없이 데이터 스트림을 비동기로 다룰 수 있는 공통 메커니즘이며, 이 메커니즘을 편리하게 사용할 수 있는 인터페이스 제공 Publisher : 데이터를 만들어 통지하는 생산자 Subscriber : 데이터를 받아 처리하는 소비자 Publisher와 Subscriber는 아래 4개의 프로토콜로 데이터를 통지함 onSubscribe : 데이터 통지가 준비됐음을 통지 ... Reactive Streamsspring webfluxReactive Streams